# coding=utf-8
from celery_tasks.task01 import send_email
from datetime import datetime, timedelta

# 利用时差方式让celery执行一个定时任务

# 当前时间
ctime = datetime.now()
# 默认用utc时间
# 时间戳timestamp 转国际时间
utc_ctime = datetime.utcfromtimestamp(ctime.timestamp())
# 时差
time_delay = timedelta(seconds=10)
task_time = utc_ctime + time_delay

# apply_async 接收更多的参数 eta 接收时间对象
result = send_email.apply_async(args=["bob", ], eta=task_time)
print(result.id)
